cothema / reliable-socket-io-request

import { ISocketEmitter } from "../interfaces/i-socket-emitter";

import { ReliableSocketRequestEmitter } from "../internal/reliable-socket-request-emitter";

import { ReliableSocketRequestReceiver } from "../internal/reliable-socket-request-receiver";

/**

 * Mostly for server side

 */

export class ReliableSocketRequestService {

    private emitter: ReliableSocketRequestEmitter;

    private receiver: ReliableSocketRequestReceiver;

    public constructor() {

        this.emitter = new ReliableSocketRequestEmitter();

        this.receiver = new ReliableSocketRequestReceiver();

    }

    /**

     * Returns promise with response.

     *

     * @param eventName

     * @param emitDataPack

     * @param options

     */

    public emit(

        socket: ISocketEmitter,

        eventName: string,

        body: any,

        options: Partial<IReliableSocketEmitOptions> = {},

    ): Promise<any> {

        return this.emitter.emit(socket, eventName, body, options);

    }

    public once(

        socket: ISocketEmitter,

        eventName: string,

        callback: () => void,

    ) {

        this.receiver.once(socket, eventName, callback);

    }

}